package com.biubiux2.async.consumer;

import com.biubiux2.async.consumer.entity.MsgEvent;
import com.lmax.disruptor.EventHandler;

/**
 * @author Lijinbao
 * @since 8/8/2022 1:36 PM
 */
public class MsgEventHandler implements EventHandler<MsgEvent> {
    @Override
    public void onEvent(MsgEvent msgEvent, long l, boolean b) throws Exception {
        msgEvent.consume();
    }
}
